package com.ittest.service.impl.activemq;

import com.ittest.service.MessageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Service;

//@Service
public class MessageServiceActivemqImpl implements MessageService {


    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    @Override
    public void sendMessage(String id) {
        System.out.println("带发送短信的订单已纳入处理队列，id："+id);
        jmsMessagingTemplate.convertAndSend("order.queues.id",id); //"order.queues.id" 可以直接在代码中写一个队列名，这样我们可以在配置中使用一个默认的队列名，在具体的代码位置写业务相关的队列名字


    }

    @Override
    public String doMessage() {
        String id = jmsMessagingTemplate.receiveAndConvert("order.queues.id",String.class);
        System.out.println("已完成短信发送业务，id："+id);
        return id;
    }
}
